package com.king.spark.rdd.transform

import org.apache.spark.{SparkConf, SparkContext}

/**
 * @Author wdl
 * @Date 2022/11/22 16:34
 */
object Spark_RDD_intersection {

  def main(args: Array[String]): Unit = {


    val sparkConf = new SparkConf().setMaster("local[*]").setAppName("WordCount")

    val sparkContext: SparkContext = new SparkContext(sparkConf)

    val dataRDD1 = sparkContext.makeRDD(List(1,2,3,4), 2)
    val dataRDD2 = sparkContext.makeRDD(List(3,4,5,6), 1)
    val dataRDD = dataRDD1.intersection(dataRDD2)
    //交集
//    dataRDD.collect().foreach(println)
    //并集
//    dataRDD1.union(dataRDD2).collect().foreach(println)

    dataRDD1.subtract(dataRDD2).collect().foreach(println)
    sparkContext.stop()
  }
}
